import os
import subprocess
import random

import threading
from queue import Queue

from threading import Thread




class Task(object):
	def __init__(self, src_file):
		self.src_file = src_file


class VideoPipeline(object):
	def __init__(self):
		self.queue = Queue()

	def add(self ,task):
		pass
	def run(self):
		pass
	def _video_info(self):
		pass
	def _need_compress(self):
		pass
	def _compress(self):
		'''
		*(mp4,avi,wmv...) -> mp4 and compress
		'''
		pass
	def _resize(self):
		pass
	def _capture(self):
		pass
	def _mpeg_dash(self):
		pass
	def _clean(self):
		pass
	def _save_video_info(self):
		pass
	def _update_video_info(self):
		pass